package boot

import (
	"context"
	"fmt"

	"yunj/pkg/global"

	"github.com/redis/go-redis/v9"
)

// 初始化Redis连接
func InitRedis() {
	client := redis.NewClient(&redis.Options{
		Addr:     fmt.Sprintf("%s:%s", global.Config.Redis.Host, global.Config.Redis.Port),
		Password: global.Config.Redis.Password,
		DB:       global.Config.Redis.DB,
	})
	// 测试连接是否成功
	pong, err := client.Ping(context.Background()).Result()
	if err != nil {
		panic(fmt.Sprintf("无法连接到 Redis: %v\n", err))
	}
	fmt.Printf("已连接到 Redis，响应: %s\n", pong)

	global.Redis = client
}
